package RDD

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object Spark02_RDD_File {

  def main(args: Array[String]): Unit = {

    // sc
    // local[*] 核模拟并行度 local 单线程
    val conf = new SparkConf().setAppName("spark").setMaster("local[*]")

    val sc = new SparkContext(conf)

    // get data

//    val rdd:RDD[String] = sc.textFile("datas/1.txt")
    val rdd:RDD[String] = sc.textFile("datas")


    // close sc
    rdd.collect().foreach(println)
    sc.stop()
  }

}
